pay/views.py

@@ -7,6 +7,7 @@ from logit import logit

                 from paginator import pagination
              

                 from pywe_exception import WeChatPayException
              

                 from pywe_pay import WeChatPay
              

                +from pywe_pay_notify import check_pay_notify
              

                 from pywe_response import WXPAY_NOTIFY_FAIL, WXPAY_NOTIFY_SUCCESS
              

                 from pywe_sign import check_signature
              

                 from pywe_xml import xml_to_dict
              
@@ -208,7 +209,7 @@ def wx_order_query_api(request):

                     # 订单查询
              

                     query_data = wxpay.order.query(transaction_id, order_id)
              

                     # 签名校验
              

                -    if not check_signature(query_data):
              

                +    if not check_signature(query_data, wechat.get('apiKey')):
              

                         return response(OrderStatusCode.SIGN_CHECK_FAIL)
              

                 
              

                     # 交易状态
              
@@ -266,19 +267,8 @@ def wx_order_detail_api(request):

                 @transaction.atomic
              

                 def wx_notify_url_api(request):
              

                     """ 支付异步通知回调地址 """
              

                -    data = xml_to_dict(request.body)
              

                -    if isinstance(data, basestring):
              

                -        return HttpResponse(WXPAY_NOTIFY_FAIL)
              

                -
              

                -    trade_type = data.get('trade_type', '')
              

                -
              

                -    # 签名校验
              

                -    if not check_signature(data, settings.WECHAT.get(trade_type, {}).get('apiKey')):
              

                -        return HttpResponse(WXPAY_NOTIFY_FAIL)
              

                -
              

                -    # 通信标识
              

                -    return_code = data.get('return_code', '')
              

                -    if return_code != 'SUCCESS':
              

                +    data, success = check_pay_notify(request.body, wx_configs=settings.WECHAT)
              

                +    if not success:
              

                         return HttpResponse(WXPAY_NOTIFY_FAIL)
              

                 
              

                     out_trade_no = data.get('out_trade_no', '')
              

requirements.txt

@@ -30,6 +30,7 @@ pywe-jssdk==1.0.2

                 pywe-miniapp==1.0.0
              

                 pywe-oauth==1.0.3
              

                 pywe-pay==1.0.5
              

                +pywe-pay-notify==1.0.1
              

                 pywe-response==1.0.1
              

                 pywe-sign==1.0.5
              

                 pywe-xml==1.0.0